<?php
	include_once('pdo.class.php');
	
	set_time_limit(600);
	
	//CONECTA BANCO DE DADOS ANTIGO
	$obj = new DB();
	$obj->conexao('0');

	//CONSULTA PROCESSOS BD ANTIGO
	$sql = "SELECT * FROM processos";
	$processos = $obj->select($sql);
	$obj = null;
	
	//ADD PROCESSOS
	foreach($processos as $p){
		$insert = null;
		$disproju = new DB();
		$disproju->conexao('1');
		
		
				
		$status = '1';
		if($p['tramite'] == 'A'){
			$status = '0';
			//INSERE MOVIMENTACAO ARQUIVADO
				
			//ARRAY DADOS INSERT
			$insert = array(
				':processo_id'=> $p['idprocessos'],
				':usuario_id'=> $p['fkadvogados'],
				':tipoevento_id'=> '9',
				':local_id'=> '2',
				':dt_evento'=>null,
				':status'=> 'A',
				':dt_cadastro'=> $p['data']." 08:00:00",
				':observacao'=> 'PROCESSO ARQUIVADO'
			);
			
		}
		
		$cd_bic = null;
		if($p['codbic'] != '0'){
			$cd_bic = $p['codbic'];
			//INSERE MOVIMENTACAO ARQUIVADO
			
		}
		
		$cpf = null;
		if($p['cpfcnpj'] != '' || $p['cpfcnpj'] != NULL){
			$cpf = 'CPF/CNPJ: '.$p['cpfcnpj'];
			//INSERE MOVIMENTACAO ARQUIVADO
			
		}
		
		$mov = 'E';
		if($p['tramite'] == 'S'){
			$mov = 'S';
			//INSERE MOVIMENTACAO SAIDA
			$insert = array(
				':processo_id'=> $p['idprocessos'],
				':usuario_id'=> $p['fkadvogados'],
				':tipoevento_id'=> '2',
				':local_id'=> $p['local_saida_processo'],
				':dt_evento'=> $p['data_saida_processo'],
				':status'=> 'A',
				':dt_cadastro'=> $p['data']." 08:00:00",
				':observacao'=> 'DEVOLUCAO DE CARGA'
			);
			
		}
		
		if($p['redistribuicao'] == '0'){
			$p['redistribuicao'] = null;
		}else{
			//INSERE MOVIMENTACAO REDISTRIBUICAO
			$insert = array(
				':processo_id'=> $p['idprocessos'],
				':usuario_id'=> $p['redistribuicao'],
				':tipoevento_id'=> '8',
				':local_id'=> '2',
				':dt_evento'=>null,
				':status'=> 'RA',
				':dt_cadastro'=> $p['data']." 08:00:00",
				':observacao'=> 'REDISTRIBUICAO AUTOMATICA'
			);
		}
		
		$sql = "INSERT INTO processos SET id=:id, tipoprocesso_id=:tipoprocesso_id, dt_processo=:dt_processo, numeroprocesso=:numeroprocesso, 
		observacao=:observacao, cd_bic=:cd_bic, usuario_id=:usuario_id, usuario_id_redist=:usuario_id_redist, assunto_id=:assunto_id, 
		status=:status, dt_cadastro=:dt_cadastro, mov=:mov";
		
		
		$ins = array(
			':id'=> $p['idprocessos'],
			':tipoprocesso_id'=> $p['fktipoprocesso'],
			':dt_processo'=> $p['data'],
			':numeroprocesso'=> $p['numeroprocesso'],
			':observacao'=> $p['observacao']." - ".$cpf,
			':cd_bic'=> $cd_bic,
			':usuario_id'=> $p['fkadvogados'],
			':usuario_id_redist'=> $p['redistribuicao'],
			':assunto_id'=> '1',
			':status'=>$status,
			':dt_cadastro'=> $p['data']." 08:00:00",
			':mov'=>$mov
		);

		$rows = $disproju->insert($sql,$ins);
		
		//*********************************************************************
		//INSERE PARTES
		$sql = "INSERT INTO partes_processos SET 
		parte_id=:parte_id, 
		processo_id=:processo_id, 
		tipos_parte=:tipos_parte
		";
		//INSERRE AUTOR
		$ins = array(
			':parte_id'=> '3',
			':processo_id'=> $p['idprocessos'],
			':tipos_parte'=> 'A'
		);
		$rows = $disproju->insert($sql,$ins);
		
		//INSERE REU
		$ins = array(
			':parte_id' => '1',
			':processo_id' => $p['idprocessos'],
			':tipos_parte' => 'R'
		);
		$rows = $disproju->insert($sql,$ins);
		
		//*********************************************************************
		// INSERE MOVIMENTACAO ENTRADA
		$sql = "INSERT INTO processos_usuarios SET 
			processo_id=:processo_id, 
			usuario_id=:usuario_id,
			dt_cadastro =:dt_cadastro
		";
		//ARRAY DADOS INSERT
		$ins = array(
			':processo_id'=> $p['idprocessos'],
			':usuario_id'=> $p['fkadvogados'],
			':dt_cadastro'=> $p['data']." 08:00:00"
		);
		$rows = $disproju->insert($sql,$ins);
		
		//ADD MOVIMENTACOES
		//INSTRUCAO PROCESSO_USUARIOS
		$sqlmov = "INSERT INTO processos_usuarios SET 
		processo_id=:processo_id, 
		usuario_id=:usuario_id, 
		tipoevento_id=:tipoevento_id, 
		local_id=:local_id, 
		dt_evento=:dt_evento, 
		status=:status, 
		dt_cadastro=:dt_cadastro, 
		observacao=:observacao
		";
		if(!empty($insert)){
			$rows = $disproju->insert($sqlmov,$insert);
		}
		//**********************************************************************

		$disproju = null;
	}
	
	echo 'SUCESSO';
	

		
	/*	
	`status` ENUM('E','S','D','AE','AA','AR','AC','AF','PE','PA','PR','PC','PF','RA','RS','AS','A','ASR') NULL DEFAULT 'E' COMMENT '- E: quando o processo é cadastrado no sistema.\\\\\\\\n- S: quando o processo retorna de uma SAIDA ao responsável.\\\\\\\\n- D: quando o processo é desarquivado.\\\\\\\\n- S: quando o processo é enviado para fora do PROJU.\\\\\\\\n- AE: quando a audiência é marcada\\\\\\\\n- AA: quando a audiência é adiada.?????\\\\\\\\n- AR: quando a audiência é remarcada.\\\\\\\\n- AC: quando a audiência é cancelada.\\\\\\\\n- AF: quando a audiência é finalizada.\\\\\\\\n- PE: quando a perícia é marcada\\\\\\\\n- PA: quando a perícia é adiada.??????\\\\\\\\n- PR: quando a perícia é remarcada.\\\\\\\\n- PC: quando a perícia é cancelada.\\\\\\\\n- PF: quando a perícia é finalizada.\\\\\\\\n- RA: quando o processo é redistribuído para outro advogado automaticamente.\\\\\\\\n- RF: quando o processo é redistribuído para outro advogado manualmente.',
	`observacao` VARCHAR(200) NULL DEFAULT 'ENTRADA PROJU',
	*/
?>	

			